package com.bd08.flink.demo.zhang

import org.apache.flink.api.scala.{ExecutionEnvironment, createTypeInformation}

object RepartitionDemo  extends App {

  val benv = ExecutionEnvironment.getExecutionEnvironment
  val ds = benv.generateSequence(1,10)
  val result = ds.mapPartition( in =>{
    in map((_,1))
  })
  result.print()

}
